package com.atguigu.realtime.util;


import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public  class  ThreadPoolUtil {
    public static ThreadPoolExecutor getThreadPool(){

        return new ThreadPoolExecutor(
                300,
                500,
                30,
                TimeUnit.SECONDS,
                new PriorityBlockingQueue<>(100)
        );
    }

}
